package com.cl.unipay4j.wx.pay;

import com.cl.unipay4j.core.IPayConfig;
import com.cl.unipay4j.core.Result;
import com.cl.unipay4j.core.UnipayConst;
import com.cl.unipay4j.core.pay.ICancel;
import com.cl.unipay4j.core.pay.PayCancelModel;
import com.cl.unipay4j.core.util.EnumUtil;
import com.cl.unipay4j.core.util.StrUtil;
import com.cl.unipay4j.wx.AbstractWxPay;
import com.cl.unipay4j.wx.sdk.WXPayConstants;
import lombok.extern.slf4j.Slf4j;

import java.util.HashMap;
import java.util.Map;

/**
 * 微信交易撤销接口
 *
 * 支付交易返回失败或支付系统超时，调用该接口撤销交易。如果此订单用户支付失败，微信支付系统会将此订单关闭；如果用户支付成功，微信支付系统会将此订单资金退还给用户。
 *
 * 注意：7天以内的交易单可调用撤销，其他正常支付的单如需实现相同功能请调用申请退款API。提交支付交易后调用【查询订单API】，没有明确的支付结果再调用【撤销订单API】。
 *
 * 调用支付接口后请勿立即调用撤销订单API，建议支付后至少15s后再调用撤销订单接口。
 *
 * @Author Small
 * @Date 2020/7/30 10:43
 * @Version 1.0
 **/
@Slf4j
public class WxPayCancel extends AbstractWxPay implements ICancel {
    public WxPayCancel() {
    }

    public WxPayCancel(IPayConfig payConfig) {
        super(payConfig);
    }

    /**
     * 撤销操作
     *
     * @param model
     * @return
     */
    @Override
    public Result execCancel(PayCancelModel model) {
        log.info("WxCancel::=>订单{} 请求到达", model.getOrderNo());
        try {
            wxPayConfig.setTradeType(EnumUtil.getIEnum(WxTradeTypeEnum.class,model.getTradeType()));
            Map<String, String> r = initWxPay().reverse(wrapParam(model));
            log.info("WxCancel::=>订单{} 返回报文，{}", model.getOrderNo(), r);
            String returnCode = r.get(WXPayConstants.RETURN_CODE);
            if (UnipayConst.SUCCESS.equals(returnCode)) {
                if (UnipayConst.SUCCESS.equals(r.get(WXPayConstants.RESULT_CODE))) {
                   return Result.tradeSuccess(r);
                } else {
                    String errCode = r.get(WXPayConstants.ERR_CODE);
                    String errCodeDes = r.get(WXPayConstants.ERR_CODE_DES);
                    log.info("WxCancel::=>订单{} 撤销失败,错误代码{},错误原因{}", model.getOrderNo(), errCode, errCodeDes);
                    return Result.returnFail(errCode, errCodeDes);
                }
            } else {
                String returnMsg = r.get(WXPayConstants.RETURN_MSG);
                log.info("WxCancel::=>订单{} 撤销失败,错误代码{},错误原因{}", model.getOrderNo(), returnCode, returnMsg);
                return Result.returnFail(returnCode, returnMsg);
            }

        } catch (Exception e) {
            log.warn("WxCancel=>订单{} 撤销时发生异常", model.getOrderNo(), e);
        }
        return Result.exception();
    }

    private Map<String, String> wrapParam(PayCancelModel model) {
        Map<String, String> map = new HashMap<>();
        if (StrUtil.isNotEmpty(model.getTradeNo())){
            map.put("transaction_id",model.getTradeNo());
        }
        if (StrUtil.isNotEmpty(model.getOutTradeNo())){
            map.put("out_trade_no",model.getOutTradeNo());
        }
        return map;
    }
}
